import threading
import time

def worker(num):
    """线程执行函数"""
    print(f"线程 {num} 开始执行")
    time.sleep(2)  # 模拟耗时操作
    print(f"线程 {num} 执行结束")

# 创建线程列表
threads = []
for i in range(5):
    t = threading.Thread(target=worker, args=(i,))
    threads.append(t)
    t.start()  # 启动线程

# 等待所有线程完成
for t in threads:
    t.join()

print("所有线程执行完毕")

